package com.navercorp.pinpoint.web.kafka;

import com.navercorp.pinpoint.web.util.BeanUtils;
import org.apache.kafka.common.serialization.Deserializer;

import java.util.Map;

public class DecodingKafka implements Deserializer {
    @Override
    public void configure(Map map, boolean b) {

    }

    @Override
    public Object deserialize(String s, byte[] bytes) {
        return BeanUtils.byteToObj(bytes);
    }

    @Override
    public void close() {

    }
}
